package com.example.cloudstremrocketmqconsumer8802.channal;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @ClassName: CustomerBinder
 * @Description:
 * @Date 2024/03/05 15:40
 * @Author songshaoqiu
 **/
public interface CustomerBinder {

    String topiceOne="one-input";

    String testTopic ="test-input";
    @Input("one-input")
    SubscribableChannel sendToOneChannel();

    @Input("test-input")
    SubscribableChannel sendTestOneChannel();
}
